from pyspark.sql import SparkSession
# Driver
spark = SparkSession \
    .builder \
    .master('local') \
    .appName('HelloSpark') \
    .getOrCreate()

# master： 指定运行模型，yarn、mesos、standalone、本地 local
# appName：spark程序的名字

df = spark.read.text('test.txt')
df.show(truncate=False)